from dask.distributed import Worker
import time

if __name__ == '__main__':
    worker1 = Worker(scheduler_ip='10.204.41.211',scheduler_port=8000,lifetime='1h')
    print(worker1)
    # worker2 = Worker(scheduler_ip='10.204.41.211',scheduler_port=8000,name='worker2')
    # worker3 = Worker(scheduler_ip='10.204.41.211',scheduler_port=8000,name='worker3')

    while True:
        time.sleep(3)